

./bin/kafka-topics.sh --bootstrap-server 175.27.191.203:9091,175.27.191.203:9092 --create --topic wordFreq \
--partitions 4 --replication-factor 2

./bin/kafka-console-consumer.sh --bootstrap-server 175.27.191.203:9092 --topic wordFreq --from-beginning

./bin/kafka-console-producer.sh --broker-list 175.27.191.203:9091,175.27.191.203:9092 --topic wordFreq
